# coding: utf-8

from elasticsearch import Elasticsearch

es = Elasticsearch(hosts="172.16.202.33:9200")
body = {
    'query': {
        'match_all': {}
    }
}
es.delete_by_query(index='ztjy-recall', doc_type='content_info', body=body)
